package org.example.flink;

import org.apache.flink.table.functions.TableFunction;

/**
 * Created by McClone on 2020/5/11.
 */
public class MutilFun extends TableFunction<String> {

    public void eval(String str) {
        for (String s : str.split(",")) {
            collect(s);
            // use collect(...) to emit a row
//            collect(new Tuple2<String, Integer>(s, s.length()));
        }
    }
}
